package com.camemax.rabbitmq.headers_mode;

import com.camemax.rabbitmq.utils.PublisherModules;

import java.util.HashMap;
import java.util.Map;

public class HeadersMode_Publisher {
    public static void main(String[] args) {
        Map<String, Object> headersType = new HashMap<>();
        Map<String, Object> headersAuthor = new HashMap<>();
        Map<String, Object> headersTag = new HashMap<>();

        headersType.put("type", "HEADERS");
        headersAuthor.put("author", "CAMEMAX");
        headersTag.put("tag", "RABBITMQ");
        new PublisherModules().publishMessage("headers-exchange", "headers-rk", headersType ,"Publisher sends out [headersType] in headers mode by Java!");
        new PublisherModules().publishMessage("headers-exchange", "headers-rk", headersAuthor ,"Publisher sends out [headersAuthor] in headers mode by Java!");
        new PublisherModules().publishMessage("headers-exchange", "headers-rk", headersTag ,"Publisher sends out [headersTag] in headers mode by Java!");
    }
}
